package com.dhy.canal;

/**
 * @author 大忽悠
 * @create 2022/12/27 9:57
 */
public interface CanalMessageListener<T> {
    /**
     * 插入消息
     */
    default void insert(T newRecord){};
    /**
     * 更新消息
     */
    default void update(T newRecord,T oldRecord){};
    /**
     * 删除消息
     */
    default void delete(T oldRecord){};
}
